package com.intct.common;

/**
 * @author gufg
 * @since 2025-07-27 11:04
 */
public class Constant {
    public static final String KAFKA_ODS_DB_TOPIC = "ods-db";

    public static final String KAFKA_ODS_LOCUS_TOPIC = "ods_locus";
    public static final String KAFKA_DWD_LOCUS_TOPIC = "dwd_locus";

    public static final String KAFKA_ODS_VEHICLE_TOPIC = "ods_vehicle";

    public static final String KAFKA_DWD_VEHICLE_TOPIC = "dwd_vehicle";

    public static final String KAFKA_DWS_VEHICLE_TOPIC = "dws_vehicle";

    public static final String MYSQL_CDC_JSON_KEY_SOURCE = "source";
    public static final String MYSQL_CDC_JSON_KEY_SOURCE_DB = "db";
    public static final String MYSQL_CDC_JSON_KEY_SOURCE_TABLE = "table";
    public static final String MYSQL_CDC_JSON_KEY_TRANSTACTION = "transaction";
    public static final String MYSQL_CDC_JSON_KEY_AFTER = "after";

    public static final String MYSQL_CDC_JSON_KEY_BEFORE = "before";
    public static final String MYSQL_CDC_JSON_KEY_OP = "op";
}
